type google.golang.org/grpc/internal/transport.controlBuffer

13 uses

	google.golang.org/grpc/internal/transport (current package)
		controlbuf.go#L307: type controlBuffer struct {
		controlbuf.go#L327: func newControlBuffer(done <-chan struct{}) *controlBuffer {
		controlbuf.go#L328: 	return &controlBuffer{
		controlbuf.go#L338: func (c *controlBuffer) throttle() {
		controlbuf.go#L348: func (c *controlBuffer) put(it cbItem) error {
		controlbuf.go#L360: func (c *controlBuffer) executeAndPut(f func() bool, it cbItem) (bool, error) {
		controlbuf.go#L404: func (c *controlBuffer) get(block bool) (any, error) {
		controlbuf.go#L431: func (c *controlBuffer) getOnceLocked() (any, error) {
		controlbuf.go#L454: func (c *controlBuffer) finish() {
		controlbuf.go#L515: 	cbuf      *controlBuffer
		controlbuf.go#L542: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator, conn net.Conn, logger *grpclog.PrefixLogger, goAwayHandler func(*goAway) (bool, error), bufferPool mem.BufferPool) *loopyWriter {
		http2_client.go#L98: 	controlBuf *controlBuffer
		http2_server.go#L90: 	controlBuf *controlBuffer